MqttEncoder

Undocumented in source.

class MqttEncoder : MessageToByteEncoder!MqttMsg {

ubyte[] encode(MqttMsg msg);

void callBack(ubyte[] data, size_t len);

static ByteBuf doEncode(MqttMsg message);

}

Members

Functions

callBack void callBack(ubyte[] data, size_t len): Undocumented in source. Be warned that the author may not have intended to support it.
encode ubyte[] encode(MqttMsg msg): Undocumented in source. Be warned that the author may not have intended to support it.

Static functions

doEncode ByteBuf doEncode(MqttMsg message): This is the main encoding method. It's only visible for testing.

Meta

Source

See Implementation

collie codec mqtt mqttencoder classes

MqttEncoder